# -*- coding: utf-8 -*-
from datetime import timedelta
from airflow.operators.bash import BashOperator
from jms_dm_oms.dm.dm_weight_flow_daily_summary_dimension_mt import jms_dm_oms__dm_weight_flow_daily_summary_dimension_mt

jms_dm_oms_oracle__dm_weight_flow_daily_summary_dimension_mt = BashOperator(
    task_id='jms_dm_oms_oracle__dm_weight_flow_daily_summary_dimension_mt',
    execution_timeout=timedelta(hours=2),
    email=['jarl.huang@jtexpress.com','yl_bigdata@yl-scm.com'],
    bash_command="jms_dm_oms/oracle/dm_weight_flow_daily_summary_dimension_mt/execute.sh",
    pool='spmi_apack',
    retries=1,
    pool_slots=2,
)

jms_dm_oms_oracle__dm_weight_flow_daily_summary_dimension_mt << [jms_dm_oms__dm_weight_flow_daily_summary_dimension_mt]